Namespace RdKafka

Global configuration that is passed to Consumer or Producer constructors.

High-level Kafka Consumer, receives messages from a Kafka cluster.

Requires Kafka >= 0.9.0.0.

Kafka Consumer that forwards received messages as events to the application.

Thin abstraction on top of Consumer.

Shared base of Consumer and Producer.

Miscellaneous APIs for the RdKafka library itself.

High-level, asynchronous message producer.

Handle to a topic obtained from Producer.

Topic-specific configuration.

Internal errors to rdkafka are prefixed with _

The partitioner may be called in any thread at any time, it may be called multiple times for the same message/key.

Partitioner function constraints:

• MUST NOT call any RdKafka methods except forPartitionAvailable(Int32)
• MUST NOT block or execute for prolonged periods of time.
• MUST return a value between 0 and partition_cnt-1, or the special RdKafka.Topic.RD_KAFKA_PARTITION_UA value if partitioning could not be performed.